package com.cloud.consumer;

import com.cloud.consumer.consumer.SimpleInput;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

/**
 * @Author: TongRui乀
 * @Date: 2019/10/29 11:29
 * @description：
 */
@Slf4j
@EnableBinding(SimpleInput.class)
public class SimpleConsumer {


    @StreamListener(SimpleInput.IN_PUT)
    public void handle(String message){

      log.info(message);

    }
}
